package com.example.mq.common;

import java.io.Serializable;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: WHY
 * Date: 2023-09-07
 * Time: 13:48
 */
public class BasicConsumeArguments extends BasicArguments implements Serializable {
    private  String consumeTag;

    public String getConsumeTag() {
        return consumeTag;
    }

    public void setConsumeTag(String consumeTag) {
        this.consumeTag = consumeTag;
    }

    public String getQueueName() {
        return queueName;
    }

    public void setQueueName(String queueName) {
        this.queueName = queueName;
    }

    public boolean isAutoAck() {
        return autoAck;
    }

    public void setAutoAck(boolean autoAck) {
        this.autoAck = autoAck;
    }

    private  String queueName;
    private  boolean autoAck;

    //这个类对应的basicConsume方法中,还有一个参数,是回调函数(处理消息)

    //这个回调函数是不能通过网络进行传输的
    //站在broker server的角度,有固定的的回调函数,但是作用就只是单纯的将生产者的客户端收到的消息传输到消费者的客户端
    //客户端收到消息以后,在客户端的=这边执行用户自定义的回调即可
    //此时客户端不需要把自己的回调告诉服务器
    //这个类就不需要consumer成员
}
